package com.hujf.flink.mapreduce;

import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Author hujf
 * @Date 2022/5/23 9:58
 * @Description TODO
 */
public class Split {
    public static void main(String[] args) {
        StreamExecutionEnvironment environment = StreamExecutionEnvironment.getExecutionEnvironment();
        DataStreamSource<Integer> integerDataStreamSource = environment.fromElements(
                1, 2, 3, 4, 5, 6, 7, 8, 9, 10
        );

        environment.setParallelism(1);

    }
}
